/**  
 * 
 * @Title:  StreamResourceLoad.java   
 * @Package com.bicon.framework.exchange   
 * @Description:    TODO(用一句话描述该文件做什么)   
 * @author: 123774135@qq.com     
 * @date:   2018年7月23日 下午2:44:48   
 * @version V1.0 
 * @Copyright: 2018 www.tydic.com Inc. All rights reserved. 
 * 
 */  
package com.biconn.bigdata.common.util;

import java.io.IOException;
import java.io.InputStream;

import org.apache.avro.Protocol;
import org.apache.commons.io.IOUtils;

/**   
 * @ClassName:  StreamResourceLoad   
 * @Description:TODO(这里用一句话描述这个类的作用)   
 * @author: 123774135@qq.com 
 * @date:   2018年7月23日 下午2:44:48   
 *     
 * @Copyright: 2018 
 * 
 */
public class StreamResourceLoad implements ResourceLoad{

	private InputStream stream;
	
	public StreamResourceLoad(InputStream stream) {
		this.stream = stream;
	}
	@Override
	public Protocol loadProtocol() {
		try {
			return Protocol.parse(stream);
		} catch (IOException e) {
			
			e.printStackTrace();
		}finally {
			IOUtils.closeQuietly(stream);
		}
		return null;
	}

}
